package com.doubao.common.config;

import lombok.extern.slf4j.Slf4j;
import org.apache.rocketmq.spring.core.RocketMQTemplate;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;

@Configuration
@Slf4j
public class RocketMQConfig {

    @Bean
    @Primary
    public RocketMQTemplate rocketMQTemplate() {
        log.info("初始化RocketMQTemplate");
        return new RocketMQTemplate();
    }
}